fn mre() {
    let client = Client::new(Cluster::Localnet, std::rc::Rc::new(MockSigner));
    let program = client.program(Pubkey::new_unique()).unwrap();
    
    let listener1 = program
        .on::<MockEvent>(|_ctx, _event| {
            println!("Listener 1 received event");
        })
        .unwrap();
    std::thread::sleep(std::time::Duration::from_secs(1));
    
    // Will hang forever 
    let listener2 = program
        .on::<MockEvent>(|_ctx, _event| {
            println!("Listener 2 received event");
        })
        .unwrap();
    
    // Should hang forever if the deadlock is still present
    
    listener2.unsubscribe();
    listener1.unsubscribe();    
}

struct MockSigner;

impl solana_signer::Signer for MockSigner {
    fn pubkey(&self) -> Pubkey {
        Pubkey::default()
    }

    fn try_pubkey(&self) -> std::result::Result<Pubkey, SignerError> {
        Ok(Pubkey::default())
    }

    fn sign_message(&self, _message: &[u8]) -> Signature {
        Signature::default()
    }

    fn try_sign_message(
        &self,
        _message: &[u8],
    ) -> std::result::Result<Signature, SignerError> {
        Ok(Signature::default())
    }

    fn is_interactive(&self) -> bool {
        false
    }

}